package com.wnxy.sddfp.system.config;

import com.wnxy.sddfp.common.contants.MQConstant;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

//@Configuration
//public class RabbitConfig {
//    /**
//     * 队列:    sddfp-queue-bind
//     * 交换机:  sddfp-exchange-bind
//     * 路由key: bind-card-message
//     */
//    /**
//     * 队列
//     *     存储消息
//     * @return
//     */
//    @Bean
//    public Queue queueBind(){
//        return QueueBuilder.durable(MQConstant.SDDFP_QUEUE_BIND).build();
//    }
//
//    /**
//     *  交换机
//     *       FanoutExchange  广播交换机    (所有的队列都可以收到消息)               一个模块给多个模块发送消息 (1对多)
//     *       DirectExchange  直连交换机    (通过指定的key 发送消息到队列中)         点对点
//     *       TopicExchange   主体交换机    (通过指定的key 发送消息到队列中，key中可以使用指定的表达式)  一对多(可以过滤成指定的)
//     *
//     *
//     * @return
//     */
//    @Bean
//    public DirectExchange exchangeBind(){
//        return new DirectExchange(MQConstant.SDDFP_EXCHANGE_BIND);
//    }
//
//    /**
//     *  路由
//     * @param queueBind
//     * @param exchangeBind
//     * @return
//     */
//    @Bean
//    public Binding binding(Queue queueBind,DirectExchange exchangeBind) {
//        return BindingBuilder.bind(queueBind).to(exchangeBind).with(MQConstant.BIND_CARD_MESSAGE);
//    }
//
//    // 消息的转换器，支持发送消息时候传入对象，会自动把对象转换为json格式
//    @Bean
//    public MessageConverter messageConverter() {
//        return new Jackson2JsonMessageConverter();
//    }
//}